package com.ccc.mqtt.server;

/**
 * @author superC
 * @version 1.0.0
 * @date 2023/6/20
 */

public class NettyMqttServerThread extends Thread {

    private final int port;

    public NettyMqttServerThread(int port) {
        this.port = port;
    }

    @Override
    public void run() {
        NettyMqttServer server = new NettyMqttServer();
        server.startup(port);
    }
}
